package com.demo.common.redis.stream;

import lombok.Data;

import java.time.LocalDateTime;

/**
 * <p>
 * stream消息-死信消息（超过最大处理次数未处理成功）
 * </p>
 *
 * @author molong
 * @date 2022/6/22
 */
@Data
public class StreamDeadlyMessage<T> {

    /**
     * 消息内容 序列化为json字符串
     */
    String key;

    /**
     * 消息内容
     */
    T msg;

    /**
     * 处理次数
     */
    Integer handleCount;

    /**
     * 进入死信的时间
     */
    LocalDateTime createTime;
}
